package com.alisls.demo.springcloud.stream.rabbit.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 自定义消息通道
 *
 * @author Ke Wang
 * @date 2020/10/15
 */
public interface MyProcessor {

    /**
     * 读取消息通道
     */
    String MY_INPUT = "myInput";

    /**
     * 生产消息通道
     */
    String MY_OUTPUT = "myOutput";

    /**
     * 创建输入通道 myInput
     * @return
     */
    @Input("myInput")
    MessageChannel myInput();

    /**
     * 创建输入通道 myOutput
     * @return MessageChannel
     */
    @Output("myOutput")
    MessageChannel myOutput();

}
